@startuml
namespace writer {
    class Writer << (S,Aquamarine) >> {
        - log *zap.SugaredLogger
        - producer sarama.SyncProducer
        - topic string

        + WriteMsg(key string, header string, value string, msg []byte)
        + Shutdown() error

    }
}


@enduml
